org.springframework.web.socket.sockjs.client

Class DefaultTransportRequest.ConnectCallback

java.lang.Object

org.springframework.web.socket.sockjs.client.DefaultTransportRequest.ConnectCallback

All Implemented Interfaces:

java.lang.Runnable, FailureCallback, ListenableFutureCallback<WebSocketSession>, SuccessCallback<WebSocketSession>

Enclosing class:

DefaultTransportRequest

private class DefaultTransportRequest.ConnectCallback
extends java.lang.Object
implements ListenableFutureCallback<WebSocketSession>, java.lang.Runnable

Updates the given (global) future based success or failure to connect for the entire SockJS request regardless of which transport actually managed to connect. Also implements Runnable to handle a scheduled timeout callback.

Field Summary

Fields

Modifier and Type	Field and Description
private SettableListenableFuture<WebSocketSession>	future
private java.util.concurrent.atomic.AtomicBoolean	handled
private WebSocketHandler	handler

Constructor Summary

Constructors

Constructor and Description
ConnectCallback(WebSocketHandler handler, SettableListenableFuture<WebSocketSession> future)

Method Summary

Modifier and Type	Method and Description
private void	handleFailure(java.lang.Throwable ex, boolean isTimeoutFailure)
void	onFailure(java.lang.Throwable ex) Called when the ListenableFuture fails to complete.
void	onSuccess(WebSocketSession session) Called when the ListenableFuture successfully completes.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

handler

private final WebSocketHandler handler

future

private final SettableListenableFuture<WebSocketSession> future

handled

private final java.util.concurrent.atomic.AtomicBoolean handled

Constructor Detail

ConnectCallback

public ConnectCallback(WebSocketHandler handler,
                       SettableListenableFuture<WebSocketSession> future)

Method Detail

onSuccess

public void onSuccess(WebSocketSession session)

Description copied from interface: SuccessCallback

Called when the ListenableFuture successfully completes.

Specified by:

onSuccess in interface SuccessCallback<WebSocketSession>

Parameters:

session - the result

onFailure

public void onFailure(java.lang.Throwable ex)

Description copied from interface: FailureCallback

Called when the ListenableFuture fails to complete.

Specified by:

onFailure in interface FailureCallback

Parameters:

ex - the exception that triggered the failure

run

public void run()

Specified by:

run in interface java.lang.Runnable

handleFailure

private void handleFailure(java.lang.Throwable ex,
                           boolean isTimeoutFailure)